import os
from celery import Celery
# 运行 celery -A celery_tasks.main worker -l INFO

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'love_house.settings')
# 1. 创建celery实例
app = Celery('celery_tasks')

# 2. 设置消息队列 broker
app.config_from_object('celery_tasks.config')

# 3. 需要 celery 自动检测指定包的任务
# autodiscover_tasks 参数是列表
# 列表中的元素是 tasks 的路径
app.autodiscover_tasks(['celery_tasks.sms'])